package com.example.customer.interfaceDao;


import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.annotation.StreamListener;
import org.springframework.messaging.Message;

@EnableBinding(value = {CustomerInterface.class})
public class RecoveMessager {

    @StreamListener(CustomerInterface.TEST_INT_PUT)
    public void messageInPut(Message<String> message) {
        System.out.println(" 消息接收成功：" + message.getPayload());
    }
}